package com.agan.aganjavaspyder.crawler.ct_demo;

import cn.hutool.core.util.StrUtil;
import cn.hutool.json.JSONArray;
import cn.hutool.json.JSONObject;
import cn.hutool.json.JSONUtil;
import com.geccocrawler.gecco.annotation.PipelineName;
import com.geccocrawler.gecco.pipeline.Pipeline;
import com.geccocrawler.gecco.request.HttpRequest;
import com.geccocrawler.gecco.scheduler.SchedulerContext;
import lombok.extern.slf4j.Slf4j;

import java.util.List;

/**
 * @author cglovewx
 */
@PipelineName("JsonPhontPipeline")
@Slf4j
public class JsonPhontPipeline implements Pipeline<PhoneDto> {

	@Override
	public void process(PhoneDto bean) {

		//入库对象
		log.info(bean.toString());

		System.out.println("PhoneDto---"+bean.getPrice()+""+bean.getSalesCode()+"---"+bean.getColor()+"----"+bean.getPic()+"----"+bean.getStorage());


		//保存图片



	}



}